/**
 * Created by hanj on 2019/11/4 9:20
 */
package com.springcloudkafka.demo.service;


import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;

@EnableBinding(Source.class)
public class Producer {

    private Source mySource;

    public Producer(Source mySource) {
        super();
        this.mySource = mySource;
    }

    public Source getMysource() {
        return mySource;
    }

    public void setMysource(Source mysource) {
        mySource = mySource;
    }
}
